home *** CD-ROM | disk | FTP | other *** search
/ Personal Computer World 2009 February / PCWFEB09.iso / Software / Resources / Chat & Communication / Digsby build 37 / digsby_setup.exe / lib / pyxmpp / error.pyo (.txt) < prev    next >
Encoding:
Python Compiled Bytecode  |  2008-10-13  |  13.1 KB  |  363 lines
  1. # Source Generated with Decompyle++
  2. # File: in.pyo (Python 2.5)
  3.  
  4. __revision__ = '$Id: error.py 648 2006-08-26 20:09:37Z jajcus $'
  5. __docformat__ = 'restructuredtext en'
  6. import libxml2
  7. from pyxmpp.utils import from_utf8, to_utf8
  8. from pyxmpp.xmlextra import common_doc, common_root, common_ns
  9. from pyxmpp import xmlextra
  10. from pyxmpp.exceptions import ProtocolError
  11. stream_errors = {
  12.     u'bad-format': ('Received XML cannot be processed',),
  13.     u'bad-namespace-prefix': ('Bad namespace prefix',),
  14.     u'conflict': ('Closing stream because of conflicting stream being opened',),
  15.     u'connection-timeout': ('Connection was idle too long',),
  16.     u'host-gone': ('Hostname is no longer hosted on the server',),
  17.     u'host-unknown': ('Hostname requested is not known to the server',),
  18.     u'improper-addressing': ('Improper addressing',),
  19.     u'internal-server-error': ('Internal server error',),
  20.     u'invalid-from': ('Invalid sender address',),
  21.     u'invalid-id': ('Invalid stream ID',),
  22.     u'invalid-namespace': ('Invalid namespace',),
  23.     u'invalid-xml': ('Invalid XML',),
  24.     u'not-authorized': ('Not authorized',),
  25.     u'policy-violation': ('Local policy violation',),
  26.     u'remote-connection-failed': ('Remote connection failed',),
  27.     u'resource-constraint': ('Remote connection failed',),
  28.     u'restricted-xml': ('Restricted XML received',),
  29.     u'see-other-host': ('Redirection required',),
  30.     u'system-shutdown': ('The server is being shut down',),
  31.     u'undefined-condition': ('Unknown error',),
  32.     u'unsupported-encoding': ('Unsupported encoding',),
  33.     u'unsupported-stanza-type': ('Unsupported stanza type',),
  34.     u'unsupported-version': ('Unsupported protocol version',),
  35.     u'xml-not-well-formed': ('XML sent by client is not well formed',) }
  36. stanza_errors = {
  37.     u'bad-request': ('Bad request', 'modify', 400),
  38.     u'conflict': ('Named session or resource already exists', 'cancel', 409),
  39.     u'feature-not-implemented': ('Feature requested is not implemented', 'cancel', 501),
  40.     u'forbidden': ('You are forbidden to perform requested action', 'auth', 403),
  41.     u'gone': ('Recipient or server can no longer be contacted at this address', 'modify', 302),
  42.     u'internal-server-error': ('Internal server error', 'wait', 500),
  43.     u'item-not-found': ('Item not found', 'cancel', 404),
  44.     u'jid-malformed': ('JID malformed', 'modify', 400),
  45.     u'not-acceptable': ('Requested action is not acceptable', 'modify', 406),
  46.     u'not-allowed': ('Requested action is not allowed', 'cancel', 405),
  47.     u'not-authorized': ('Not authorized', 'auth', 401),
  48.     u'payment-required': ('Payment required', 'auth', 402),
  49.     u'recipient-unavailable': ('Recipient is not available', 'wait', 404),
  50.     u'redirect': ('Redirection', 'modify', 302),
  51.     u'registration-required': ('Registration required', 'auth', 407),
  52.     u'remote-server-not-found': ('Remote server not found', 'cancel', 404),
  53.     u'remote-server-timeout': ('Remote server timeout', 'wait', 504),
  54.     u'resource-constraint': ('Resource constraint', 'wait', 500),
  55.     u'service-unavailable': ('Service is not available', 'cancel', 503),
  56.     u'subscription-required': ('Subscription is required', 'auth', 407),
  57.     u'undefined-condition': ('Unknown error', 'cancel', 500),
  58.     u'unexpected-request': ('Unexpected request', 'wait', 400) }
  59. legacy_codes = {
  60.     302: 'redirect',
  61.     400: 'bad-request',
  62.     401: 'not-authorized',
  63.     402: 'payment-required',
  64.     403: 'forbidden',
  65.     404: 'item-not-found',
  66.     405: 'not-allowed',
  67.     406: 'not-acceptable',
  68.     407: 'registration-required',
  69.     408: 'remote-server-timeout',
  70.     409: 'conflict',
  71.     500: 'internal-server-error',
  72.     501: 'feature-not-implemented',
  73.     502: 'service-unavailable',
  74.     503: 'service-unavailable',
  75.     504: 'remote-server-timeout',
  76.     510: 'service-unavailable' }
  77. STANZA_ERROR_NS = 'urn:ietf:params:xml:ns:xmpp-stanzas'
  78. STREAM_ERROR_NS = 'urn:ietf:params:xml:ns:xmpp-streams'
  79. PYXMPP_ERROR_NS = 'http://pyxmpp.jajcus.net/xmlns/errors'
  80. STREAM_NS = 'http://etherx.jabber.org/streams'
  81.  
  82. class ErrorNode:
  83.     
  84.     def __init__(self, xmlnode_or_cond, ns = None, copy = True, parent = None):
  85.         if type(xmlnode_or_cond) is str:
  86.             xmlnode_or_cond = unicode(xmlnode_or_cond, 'utf-8')
  87.         
  88.         self.xmlnode = None
  89.         self.borrowed = 0
  90.         if isinstance(xmlnode_or_cond, libxml2.xmlNode):
  91.             self._ErrorNode__from_xml(xmlnode_or_cond, ns, copy, parent)
  92.         elif isinstance(xmlnode_or_cond, ErrorNode):
  93.             if not copy:
  94.                 raise TypeError, 'ErrorNodes may only be copied'
  95.             
  96.             self.ns = from_utf8(xmlnode_or_cond.ns.getContent())
  97.             self.xmlnode = xmlnode_or_cond.xmlnode.docCopyNode(common_doc, 1)
  98.             if not parent:
  99.                 parent = common_root
  100.             
  101.             parent.addChild(self.xmlnode)
  102.         elif ns is None:
  103.             raise ValueError, 'Condition namespace not given'
  104.         elif parent:
  105.             self.xmlnode = parent.newChild(common_ns, 'error', None)
  106.             self.borrowed = 1
  107.         else:
  108.             self.xmlnode = common_root.newChild(common_ns, 'error', None)
  109.         cond = self.xmlnode.newChild(None, to_utf8(xmlnode_or_cond), None)
  110.         ns = cond.newNs(ns, None)
  111.         cond.setNs(ns)
  112.         self.ns = from_utf8(ns.getContent())
  113.  
  114.     
  115.     def __from_xml(self, xmlnode, ns, copy, parent):
  116.         if not ns:
  117.             ns = None
  118.             c = xmlnode.children
  119.             while c:
  120.                 ns = c.ns().getContent()
  121.                 if ns in (STREAM_ERROR_NS, STANZA_ERROR_NS):
  122.                     break
  123.                 
  124.                 ns = None
  125.                 c = c.next
  126.             if ns == None:
  127.                 raise ProtocolError, 'Bad error namespace'
  128.             
  129.         
  130.         self.ns = from_utf8(ns)
  131.         if copy:
  132.             self.xmlnode = xmlnode.docCopyNode(common_doc, 1)
  133.             if not parent:
  134.                 parent = common_root
  135.             
  136.             parent.addChild(self.xmlnode)
  137.         else:
  138.             self.xmlnode = xmlnode
  139.             self.borrowed = 1
  140.         if copy:
  141.             ns1 = xmlnode.ns()
  142.             xmlextra.replace_ns(self.xmlnode, ns1, common_ns)
  143.         
  144.  
  145.     
  146.     def __del__(self):
  147.         if self.xmlnode:
  148.             self.free()
  149.         
  150.  
  151.     
  152.     def free(self):
  153.         if not self.borrowed:
  154.             self.xmlnode.unlinkNode()
  155.             self.xmlnode.freeNode()
  156.         
  157.         self.xmlnode = None
  158.  
  159.     
  160.     def free_borrowed(self):
  161.         self.xmlnode = None
  162.  
  163.     
  164.     def is_legacy(self):
  165.         return not self.xmlnode.hasProp('type')
  166.  
  167.     
  168.     def xpath_eval(self, expr, namespaces = None):
  169.         ctxt = common_doc.xpathNewContext()
  170.         ctxt.setContextNode(self.xmlnode)
  171.         ctxt.xpathRegisterNs('ns', to_utf8(self.ns))
  172.         if namespaces:
  173.             for prefix, uri in namespaces.items():
  174.                 ctxt.xpathRegisterNs(prefix, uri)
  175.             
  176.         
  177.         ret = ctxt.xpathEval(expr)
  178.         ctxt.xpathFreeContext()
  179.         return ret
  180.  
  181.     
  182.     def get_condition(self, ns = None):
  183.         if ns is None:
  184.             ns = self.ns
  185.         
  186.         c = self.xpath_eval('ns:*')
  187.         if not c:
  188.             self.upgrade()
  189.             c = self.xpath_eval('ns:*')
  190.         
  191.         if not c:
  192.             return None
  193.         
  194.         if ns == self.ns and c[0].name == 'text':
  195.             if len(c) == 1:
  196.                 return None
  197.             
  198.             c = c[1:]
  199.         
  200.         return c[0]
  201.  
  202.     
  203.     def get_text(self):
  204.         c = self.xpath_eval('ns:*')
  205.         if not c:
  206.             self.upgrade()
  207.         
  208.         t = self.xpath_eval('ns:text')
  209.         if not t:
  210.             return None
  211.         
  212.         return from_utf8(t[0].getContent())
  213.  
  214.     
  215.     def add_custom_condition(self, ns, cond, content = None):
  216.         c = self.xmlnode.newTextChild(None, to_utf8(cond), content)
  217.         ns = c.newNs(to_utf8(ns), None)
  218.         c.setNs(ns)
  219.         return c
  220.  
  221.     
  222.     def upgrade(self):
  223.         if not self.xmlnode.hasProp('code'):
  224.             code = None
  225.         else:
  226.             
  227.             try:
  228.                 code = int(self.xmlnode.prop('code'))
  229.             except (ValueError, KeyError):
  230.                 code = None
  231.  
  232.         if code and legacy_codes.has_key(code):
  233.             cond = legacy_codes[code]
  234.         else:
  235.             cond = None
  236.         condition = self.xpath_eval('ns:*')
  237.         if condition:
  238.             return None
  239.         elif cond is None:
  240.             condition = self.xmlnode.newChild(None, 'undefined-condition', None)
  241.             ns = condition.newNs(to_utf8(self.ns), None)
  242.             condition.setNs(ns)
  243.             condition = self.xmlnode.newChild(None, 'unknown-legacy-error', None)
  244.             ns = condition.newNs(PYXMPP_ERROR_NS, None)
  245.             condition.setNs(ns)
  246.         else:
  247.             condition = self.xmlnode.newChild(None, cond, None)
  248.             ns = condition.newNs(to_utf8(self.ns), None)
  249.             condition.setNs(ns)
  250.         txt = self.xmlnode.getContent()
  251.         if txt:
  252.             text = self.xmlnode.newTextChild(None, 'text', txt)
  253.             ns = text.newNs(to_utf8(self.ns), None)
  254.             text.setNs(ns)
  255.         
  256.  
  257.     
  258.     def downgrade(self):
  259.         if self.xmlnode.hasProp('code'):
  260.             return None
  261.         
  262.         cond = self.get_condition()
  263.         if not cond:
  264.             return None
  265.         
  266.         cond = cond.name
  267.         if stanza_errors.has_key(cond) and stanza_errors[cond][2]:
  268.             self.xmlnode.setProp('code', to_utf8(stanza_errors[cond][2]))
  269.         
  270.  
  271.     
  272.     def serialize(self):
  273.         return self.xmlnode.serialize(encoding = 'utf-8')
  274.  
  275.  
  276.  
  277. class StreamErrorNode(ErrorNode):
  278.     
  279.     def __init__(self, xmlnode_or_cond, copy = 1, parent = None):
  280.         if type(xmlnode_or_cond) is str:
  281.             xmlnode_or_cond = xmlnode_or_cond.decode('utf-8')
  282.         
  283.         if type(xmlnode_or_cond) is unicode:
  284.             if not stream_errors.has_key(xmlnode_or_cond):
  285.                 raise ValueError, 'Bad error condition'
  286.             
  287.         
  288.         ErrorNode.__init__(self, xmlnode_or_cond, STREAM_ERROR_NS, copy = copy, parent = parent)
  289.  
  290.     
  291.     def get_message(self):
  292.         cond = self.get_condition()
  293.         if not cond:
  294.             self.upgrade()
  295.             cond = self.get_condition()
  296.             if not cond:
  297.                 return None
  298.             
  299.         
  300.         cond = cond.name
  301.         if not stream_errors.has_key(cond):
  302.             return None
  303.         
  304.         return stream_errors[cond][0]
  305.  
  306.  
  307.  
  308. class StanzaErrorNode(ErrorNode):
  309.     
  310.     def __init__(self, xmlnode_or_cond, error_type = None, copy = 1, parent = None):
  311.         if type(xmlnode_or_cond) is str:
  312.             xmlnode_or_cond = unicode(xmlnode_or_cond, 'utf-8')
  313.         
  314.         if type(xmlnode_or_cond) is unicode:
  315.             if not stanza_errors.has_key(xmlnode_or_cond):
  316.                 raise ValueError, 'Bad error condition'
  317.             
  318.         
  319.         ErrorNode.__init__(self, xmlnode_or_cond, STANZA_ERROR_NS, copy = copy, parent = parent)
  320.         if type(xmlnode_or_cond) is unicode:
  321.             if error_type is None:
  322.                 error_type = stanza_errors[xmlnode_or_cond][1]
  323.             
  324.             self.xmlnode.setProp('type', to_utf8(error_type))
  325.         
  326.  
  327.     
  328.     def get_type(self):
  329.         if not self.xmlnode.hasProp('type'):
  330.             self.upgrade()
  331.         
  332.         return from_utf8(self.xmlnode.prop('type'))
  333.  
  334.     
  335.     def upgrade(self):
  336.         ErrorNode.upgrade(self)
  337.         if self.xmlnode.hasProp('type'):
  338.             return None
  339.         
  340.         cond = self.get_condition().name
  341.         if stanza_errors.has_key(cond):
  342.             typ = stanza_errors[cond][1]
  343.             self.xmlnode.setProp('type', typ)
  344.         
  345.  
  346.     
  347.     def get_message(self):
  348.         cond = self.get_condition()
  349.         if not cond:
  350.             self.upgrade()
  351.             cond = self.get_condition()
  352.             if not cond:
  353.                 return None
  354.             
  355.         
  356.         cond = cond.name
  357.         if not stanza_errors.has_key(cond):
  358.             return None
  359.         
  360.         return stanza_errors[cond][0]
  361.  
  362.  
  363.